from celery import Celery
from common.celery_tasks.config import CeleryConfig

# 创建celery应用
celery_app = Celery('toutiao')
# 加载配置文件
celery_app.config_from_object(CeleryConfig)
# 自动发现任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])

if __name__ == '__main__':
    celery_app.start()
    print("starting")